package top.byteio.common.mq.pojo;

import lombok.Data;
import lombok.Getter;
import lombok.Setter;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;
import top.byteio.common.mq.factory.AbstractMqFactory;
import top.byteio.common.mq.handler.MqProducerSender;

/**
 * @Description: MQ消息配置属性
 * @Author: Snail
 * @CreateDate: 2023/11/29 10:02
 * @Version: V1.0
 */
@Data
@Component
@ConfigurationProperties(prefix = "jole.common.mq")
public class MqProperties {


    private MqExtend extend;


    /**
     * MQ扩展属性
     * @author lerryxia
     **/
    @Getter
    @Setter
    public static class MqExtend {
        private boolean enable;

        private Class<? extends AbstractMqFactory> mqFactory;

        private Class<? extends MqProducerSender> mqProducerSender;
    }

}
